package cn.gwm.flink.streaming.dwd.consumer;

import cn.gwm.flink.streaming.constant.VehicleType;
import cn.gwm.flink.streaming.dwd.check.VehicleConsumer;
import cn.gwm.utils.ConfigLoader;
import lombok.Data;
import lombok.experimental.Accessors;

/**
 * @ClassName ES11Consumer
 * @Description
 * @Author LiangGuang
 * @Date 2023/05/18 11:02
 */
@Data
@Accessors(chain = true)
public class V71PhevConsumer extends VehicleConsumer {

    public V71PhevConsumer() {
        this.topic = ConfigLoader.get("kafka.clean.topic.ods.v71");
        this.groupId = "consumer-dwd-v71phev";
        this.customType = VehicleType.POWER_TYPE_PHEV;
        this.mileage = "VehTotDistance";
        this.vehicleType = VehicleType.V71_PHEV;
        this.uidSuffix = VehicleType.V71_PHEV;
    }

    public V71PhevConsumer(String uidSuffix) {
        this.topic = ConfigLoader.get("kafka.clean.topic.ods.v71");
        this.groupId = "consumer-dwd-v71phev";
        this.customType = VehicleType.POWER_TYPE_PHEV;
        this.mileage = "VehTotDistance";
        this.vehicleType = VehicleType.V71_PHEV;
        this.uidSuffix = uidSuffix;
    }
}
